153d71b52fb6e9507dbcff3aedbc05d1a7e150f8,rxnetty-examples/src/main/java/io/reactivex/netty/examples/http/loadbalancing/HttpLoadBalancingClient.java,HttpLoadBalancingClient,main,#String[]#,51

Before Change


    public static void main(String[] args) {

        /*Start 3 embedded servers, two healthy and one unhealthy to demo failure detection*/
        final SocketAddress[] hosts = { startNewServer(OK), startNewServer(OK), startNewServer(SERVICE_UNAVAILABLE)};

        /*Create a new client using the load balancer over the hosts above.*/
        HttpClient.newClient(HttpLoadBalancer.create(hosts))

After Change


    public static void main(String[] args) {

        /*Start 3 embedded servers, two healthy and one unhealthy to demo failure detection*/
        final Observable<SocketAddress> hosts = Observable.just(startNewServer(OK), startNewServer(OK),
                                                                startNewServer(SERVICE_UNAVAILABLE));

        /*Create a new client using the load balancer over the hosts above.*/
        HttpClient.newClient(HttpLoadBalancer.create(hosts))